package com.denlaku.longan.event;

import java.util.concurrent.ThreadFactory;

/**
 * 消费者线程工厂类
 *
 * @author tianx
 */
class MessageThreadFactory implements ThreadFactory {
    @Override
    public Thread newThread(Runnable r) {
        return new Thread(r, "Simple-Disruptor-Thread");
    }
}